import os

from celery import Celery

# 1.设置配置文件,需要防止到创建celery任务
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings.dev')

# 2.创建一个celery应用
# 参数１,自定义命名
# 参数２,异步保存到redis中
celery_app = Celery("meiduo", broker="redis://127.0.0.1:6379/15")

# 3.指定要扫描任务的包,会自动读取包下的名字为task.py的文件
celery_app.autodiscover_tasks(['celery_tasks.sms'])